package vip.meeet.kafka;

import org.apache.kafka.clients.consumer.ConsumerConfig;

import java.util.Properties;

public class KafkaA {

//    private static final String ZOOKEEPER_CONNECT = "192.168.8.205:2181,192.168.8.206:2181,192.168.8.207:2181";
    private static final String ZOOKEEPER_CONNECT = "127.0.0.1:2181";


    public static void main(String[] args) {
        Properties props = new Properties();
        props.setProperty("group.id", "a");
        props.setProperty("zookeeper.connect", ZOOKEEPER_CONNECT);
        props.setProperty("socket.timeout.ms", "3000");
        props.setProperty("zookeeper.connectiontimeout.ms", "3000");
        props.setProperty("zookeeper.session.timeout.ms", "3000");
        props.setProperty("zookeeper.sync.time.ms", "3000");
        props.setProperty("consumer.timeout.ms", "3000");
        props.setProperty("auto.commit.enable", "true");
        props.setProperty("auto.commit.interval.ms", "3000");
        props.setProperty("auto.offset.reset", "largest");
        ConsumerConfig consumerConfig = new ConsumerConfig(props);
//        Consumer
    }
}
